package com.bx.flink

import org.apache.flink.api.scala.ExecutionEnvironment

object Test01 {
  def main(args: Array[String]): Unit = {
    val benv = ExecutionEnvironment.getExecutionEnvironment

  }
}
